package org.apache.flink.runtime.resourceprovider.slot;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.runtime.clusterframework.types.AllocationID;

/** Exception indicating that the given {@link ConsumingTaskSlot} was not in state active. */
public class SlotNotActiveException extends Exception {

    private static final long serialVersionUID = 4305837511564584L;

    public SlotNotActiveException(ConsumerID jobId, AllocationID allocationId) {
        super("No active slot for job " + jobId + " with allocation id " + allocationId + '.');
    }
}
